import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;


public class TestHDFS {

    public static void main(String[] args) throws Exception{

        // 1、创建一个配置类，初始化参数
        Configuration conf = new Configuration();
        // 指明HDFS的位置(namenode)
        conf.set("fs.defaultFS","hdfs://hadoop10:9000");
        // 2、创建HDFS操作的工具类
        FileSystem fileSystem = FileSystem.get(conf);
        // 3、调用工具类的方法，完成上传操作    文件路径需要封装带Path对象中
        // hdfs dfs -put 本地路径 hdfs路径
        fileSystem.copyFromLocalFile(new Path("D:\\aaa"),new Path("/"));  // 将windows上的文件上传到hdfs上面
        // 4、释放资源
        fileSystem.close();
    }

    public void test1() throws Exception{

    }


}
